package south

import (
	"fmt"
	"iot-base/common/config"
	"iot-base/common/mqtt"
)

type RecordData struct {
	Table string
	Data  interface{}
}

func handleRecord(client mqtt.IOTMQTTBroker, topic string, pCmd *mqtt.Cmd) {
	if pCmd != nil {
		fmt.Println("topic：", topic)
		fmt.Println("Body", pCmd.Body)
	} else {
		client.Reply(config.GetEdgeTopic(), pCmd, -1, "not exist "+pCmd.SourceID, nil)
	}
}
